package com.wyl.java.juc_.blockingqueue_;

import cn.hutool.core.io.FileUtil;

import java.io.File;
import java.util.Arrays;
import java.util.List;

/**
 * 日志收集系统中，可能需要多个进程同时写入同一个日志文件。这时可以使用BlockingQueue作为缓冲区，每个进程往BlockingQueue中写入日志信息，然后由专门的线程从BlockingQueue中取出日志信息并写入到文件中。
 * @author 吴宇亮 on 2023/3/28 15:20
 */
public class BlockingQueue01 {

    public static void main(String[] args) {
        System.out.println("BlockingQueue01.java:160");
//        String filePath = "E:\\workspace\\studyProject\\studyMainshi\\src\\main\\java\\com\\wyl\\java\\juc_\\blockingqueue_\\log.txt";
//        FileUtil.writeUtf8String("", filePath);
//
//        for (int i = 0; i < 10; i++) {
//            for (int j = 0; j < 10; j++) {
//                new Thread(() -> {
//                    File logFile = new File(filePath);
//                    String name = Thread.currentThread().getName();
//                    FileUtil.appendUtf8Lines(Arrays.asList(name + "到此一游!"), logFile);
//                }, "thread-" + i).start();
//            }
//        }
    }

}
